package com.chinamobile.websocket.domain.bo;

import lombok.Data;

/**
 * @className: KafkaMessageBo
 * @description KafkaMessageBo
 * @author: fanzhijun
 * @date: 2024/2/6
 **/
@Data
public class WebsocketKafkaMessageBo {
    private String uniKey; // 一对一使用
    private Integer type; // 一对多使用
    private String topic;
    private Object data;
    private Integer consumerCount;
}
